package com.kly.cashmall.baserx;


import io.reactivex.disposables.CompositeDisposable;
import io.reactivex.disposables.Disposable;

/**
 * @author zxp
 * @version $Id$
 * @since 2017/11/26 22:49
 */
public class RxManager {
    private CompositeDisposable compositeDisposable;

    public void add(Disposable disposable){
        if (compositeDisposable==null){
            compositeDisposable = new CompositeDisposable();
        }
        compositeDisposable.add(disposable);
    }

    public void clear(){
        if (compositeDisposable!=null){
            compositeDisposable.clear();
        }
    }
}
